package rabbitmq

//import (
//	"fmt"
//	"log"
//	"time"
//
//	"github.com/streadway/amqp"
//)
//
//var Chan *amqp.Channel
//
//// ConnectToRabbitMQ 连接到RabbitMQ服务器并返回一个通道
//func ConnectToRabbitMQ() (*amqp.Channel, *amqp.Connection, error) {
//	// 连接到RabbitMQ服务器
//	conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
//	if err != nil {
//		return nil, nil, fmt.Errorf("Failed to connect to RabbitMQ: %v", err)
//	}
//
//	// 创建一个通道
//	ch, err := conn.Channel()
//	if err != nil {
//		return nil, nil, fmt.Errorf("Failed to open a channel: %v", err)
//	}
//	Chan = ch
//	// 返回通道和连接
//	return ch, conn, nil
//}
//
//// SendBookingSuccessMessage 发送预定成功的消息到RabbitMQ队列
//func SendBookingSuccessMessage(channel *amqp.Channel, queueName string, userId int32, equipmentId int, startDate, endDate time.Time) error {
//	fmt.Println("-----------------")
//	// 准备消息内容
//	message := fmt.Sprintf("用户%d成功预定器材%d，时间：%s至%s", userId, equipmentId, startDate.Format("2006-01-02"), endDate.Format("2006-01-02"))
//
//	// 创建一个消息发布到队列
//	body := []byte(message) // 将消息转换为字节切片
//
//	// 发送消息到队列
//	// 假设队列已经存在，如果没有，你需要先声明它
//	err := channel.Publish(
//		"",        // exchange
//		queueName, // routing key
//		false,     // mandatory
//		false,     // immediate
//		amqp.Publishing{
//			ContentType: "text/plain",
//			Body:        body,
//		})
//	if err != nil {
//		return fmt.Errorf("failed to publish message: %s", err)
//	}
//
//	log.Printf("Sent '%s'", message)
//	fmt.Println("-----------------")
//	fmt.Println("-----------------", message)
//	return nil
//}
